簡介:本課程包含Flink重要的概念和編程模型,FlinkDataset和DataStreamAPI詳解,Flink Table和SQL的算子操作以及在實際問題中的應用。并且通過案例入手講解FlinkSQL在生產環境的使用。
第1章 課程介紹
本章主要從Flink最新版本的新特性入手,介紹了Flink的核心概念和編程模型,以及Flink未來的發展方向、FlinkSQL的優勢和生產應用。
第2章 Flink的編程模型和核心概念
本章主要講解Flink的編程模型和核心概念,包括包括水印、并行度、時間窗口、以及FlinkSQL的基本概念,并通過案例實操介紹SQL的編程模型。
第4章 Flink Table和SQL的編程模型
本章主要講解了Flink Table和SQL的編程模型以及常用的算子操作,并且介紹了SQL自帶的內置函數以及用戶如何自定義函數,以便于同學們能夠了解FlinkSQL的基礎使用。
第5章 實戰項目---NBA球星得分王排行榜
本章案例主要從NBA球星的得分數據入手,帶領同學們完成使用FlinkSQL處理數據并且計算出得分排行的功能。
第6章 實戰項目---流式計算中的應用
本章介紹了Kafka的核心概念以及本地環境的搭建,并結合案例講解了如何使用Flink消費Kafka數據,實現FlinkSQL在實時流式環境中的應用。
解鎖即可觀看《大數據工程師》完整課程視頻
大數據工程師
硬核技能帶你攻克熱點商業項目,從入門直達中級工程師水平,掌握DT時代淘金利器!
【第1周】學好大數據先攻克Linux
【第2周】大數據起源之初識Hadoop
【第3周】Hadoop之HDFS的使用
【第4周】Hadoop之HDFS核心進程剖析
【第5周】Hadoop之初識MR
【第6周】拿來就用的企業級解決方案
【第7周】Flume從0到高手一站式養成記
【第8周】數據倉庫Hive從入門到小牛
【第9周】Hive擴展內容
【第10周】快速上手NoSQL數據庫HBase
【第11周】數據分析引擎之Impala
【第12周】7天極速掌握Scala語言
【第13周】Spark快速上手
【第14周】Spark性能優化的道與術
【第15周】Spark3.x擴展內容
【第16周】綜合項目:電商數據倉庫之用戶行為數倉
【第17周】綜合項目:電商數據倉庫之商品訂單數倉
【第18周】消息隊列之Kafka從入門到小牛
【第19周】極速上手內存數據庫Redis
【第20周】Flink快速上手篇
【第21周】Flink高級進階之路
【第22周】Flink1.15新特性及狀態的使用
【第23周】Flink1.15之狀態的容錯與一致性
【第24周】FlinkSQL(1.15)快速上手
【第25周】FlinkSQL雙流JOIN詳解
【第26周】全文檢索引擎Elasticsearch
【第27周】Es+HBase仿百度搜索引擎項目
【第28周】直播平臺三度關系推薦V1.0
【第29周】直播平臺三度關系推薦V2.0
【第30周】數據中臺大屏
【第31周】實時OLAP引擎之ClickHouse
【第32周】實時數倉-Kafka Eagle+DS
【第33周】實時數倉-Flink CDC數據采集
【第34周】實時數倉-Paimon(數據湖)快速上手
【第35周】實時數倉-Paimon(數據湖)高級進階
【第36周】實時數倉-湖倉一體項目
【第37周】一站式流式開發平臺StreamPark
【第38周】大數據分布式SQL網關Kyuubi